package conversation;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;

public class Saber {
	 public static void main(String args[]) throws IOException {
	 Scanner read = new Scanner(System.in);
     Socket mysocket = null;
     //（2）在Socket通道内通过IO进行数据的读取和写入。
     DataInputStream in = null;
     DataOutputStream out= null;
     while (true) {
    	 System.out.println("请输入：");
         String a = read.next();

         try {  //（1）建立客户端的Socket服务,并明确要连接的服务器和端口号。
             mysocket = new Socket("127.0.0.1", 2010);
             //（3）通过Socket对象的方法getInputStream()和getOutputStream()，可以获取这两个流。
             in = new DataInputStream(mysocket.getInputStream());
             out = new DataOutputStream(mysocket.getOutputStream());

             out.writeUTF(a);
             String s = in.readUTF();   //in读取信息，堵塞状态
             System.out.println("客户收到服务器的回答:" + s);
             Thread.sleep(2000);
         } catch (Exception e) {
             System.out.println("服务器已断开" + e);
         }
         //（5）如果传输数据完毕，关闭资源。
     }
	 
 }
}